async with aiohttp.ClientSession() as session:
+    rate_limit = 5000  # GitHub's default rate limit
+    requests_made = 0
     while True:
         try:
+            if requests_made >= rate_limit:
+                await asyncio.sleep(3600)  # Wait for an hour if rate limit is reached
+                requests_made = 0
             await asyncio.sleep(3)
             get_logger().info("Polling for notifications")
             headers = {
                 "Accept": "application/vnd.github.v3+json",
                 "Authorization": f"Bearer {token}"
             }
+            requests_made += 1
 

-processes = []
-for func, args in task_queue: # Create  parallel tasks
-    p = multiprocessing.Process(target=func, args=args)
-    processes.append(p)
-    p.start()
-task_queue.clear()
+with multiprocessing.Pool(processes=4) as pool:  # Adjust the number of processes as needed
+    results = [pool.apply_async(func, args) for func, args in task_queue]
+    task_queue.clear()
+    # Optionally, you can wait for all tasks to complete:
+    # for result in results:
+    #     result.get()
 

 handled_ids = set()
 ...
-handled_ids.add(notification['id'])
-output = await is_valid_notification(notification, headers, handled_ids, session, user_id)
-if output[0]:
-    _, handled_ids, comment, comment_body, pr_url, user_tag = output
+if notification['id'] not in handled_ids:
+    handled_ids.add(notification['id'])
+    output = await is_valid_notification(notification, headers, handled_ids, session, user_id)
+    if output[0]:
+        _, comment, comment_body, pr_url, user_tag = output
 

-async with session.get(NOTIFICATION_URL, headers=headers, params=params) as response:
-    if response.status == 200:
-        if 'Last-Modified' in response.headers:
-            last_modified[0] = response.headers['Last-Modified']
-            since[0] = None
-        notifications = await response.json()
-        if not notifications:
-            continue
+max_retries = 3
+retry_delay = 5
+for attempt in range(max_retries):
+    try:
+        async with session.get(NOTIFICATION_URL, headers=headers, params=params) as response:
+            if response.status == 200:
+                if 'Last-Modified' in response.headers:
+                    last_modified[0] = response.headers['Last-Modified']
+                    since[0] = None
+                notifications = await response.json()
+                if not notifications:
+                    break
+                # Process notifications...
+            elif response.status == 429:  # Rate limit exceeded
+                retry_after = int(response.headers.get('Retry-After', retry_delay))
+                await asyncio.sleep(retry_after)
+            else:
+                raise Exception(f"Unexpected status code: {response.status}")
+        break  # Success, exit retry loop
+    except aiohttp.ClientError as e:
+        if attempt == max_retries - 1:
+            raise
+        await asyncio.sleep(retry_delay)